#include "../mqserver/channel.hpp"
using namespace std;

int main() {
    rbmq::channelManager::ptr cmp = make_shared<rbmq::channelManager>();
    string basedir = "./data/host1/message/";
    rbmq::VirtualHost::ptr _host = make_shared<rbmq::VirtualHost>("host1", basedir, "./data/host1/meta.db");
    cmp->openChannel(_host, make_shared<rbmq::consumerManager>(), shared_ptr<ProtobufCodec>(), muduo::net::TcpConnectionPtr(),\
     "1", make_shared<threadpool>(1)); 
    return 0;
}